package cn.com.idmy.mq.annotation;


import cn.com.idmy.mq.model.enums.MqConsumeMode;
import cn.com.idmy.mq.model.enums.MqMsgMode;

import java.lang.annotation.*;

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface MqConsumer {
    String group() default "";

    MqMsgMode msgMode() default MqMsgMode.CLUSTERING;

    MqConsumeMode consumeMode() default MqConsumeMode.CONCURRENTLY;

    String instanceNumber() default "1";
}
